package org.tity.commons.concurrent.workshop;

public interface Consumer<K,V> {
	
	/**
	 * 消费一个元素
	 * @param e  将要在consume方法中被消费的元素
	 * @param left TaskWorkshop 中剩余待消费的元素个数
	 * */
	public void consume(Element<K,V> e,int left);
	
}
